package com.ymm.system.core.config.mq;

//import org.apache.rocketmq.common.message.MessageExt;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

/**
 * @Author zikang.yao
 * @Description TODO
 * @Date 2022/8/3 15:52
 * @Version 1.0
 */

//@Component
//@RocketMQMessageListener(topic = "testTopic",consumerGroup = "consumer-group")
//public class MessageListener implements RocketMQListener<MessageExt> {
//
//    @Override
//    public void onMessage(MessageExt messageExt) {
//        String msgId = messageExt.getMsgId();
//        byte[] messageExtBody = messageExt.getBody();
//        System.out.println("消费者启动..............");
//    }
//
//}
